301d60411fb2765d1b53779b320abdb9446b8757,debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/MySqlValueConverters.java,MySqlValueConverters,schemaBuilder,#Column#,82

Before Change


        }
        if (matches(typeName, "SET")) {
            List<String> options = extractEnumAndSetOptions(column);
            StringBuilder commaSeparatedOptions = new StringBuilder();
            boolean first = true;
            for (String value:options) {
                if (first) {
                    first = false;
                } else {
                    commaSeparatedOptions.append(MySqlDdlParser.ENUM_AND_SET_DELIMINATOR);
                }
                commaSeparatedOptions.append(value);
            }
            return io.debezium.data.EnumSet.builder(commaSeparatedOptions.toString());
        }
        // Otherwise, let the base class handle it ...
        return super.schemaBuilder(column);

After Change


        }
        if (matches(typeName, "SET")) {
            List<String> options = extractEnumAndSetOptions(column);
            String commaSeperatedOptions = Strings.join(MySqlDdlParser.ENUM_AND_SET_DELIMINATOR,options);
            return io.debezium.data.EnumSet.builder(commaSeperatedOptions);
        }
        // Otherwise, let the base class handle it ...